af2eac079123f324b89c06966fd688a4c5e19432,src/main/java/com/continuuity/gateway/consumer/TupleWritingConsumer.java,TupleWritingConsumer,batch,#List#,53
Before Change
destination = "default";
}
// construct the stream URI to use for the data fabric
String queueURI = FlowStream.buildStreamURI(destination);
operations.add(new QueueEnqueue(queueURI.getBytes(), bytes));
LOG.debug("Sending tuple to " + queueURI + ", tuple = " + event);
After Change
destination = "default";
}
// construct the stream URI to use for the data fabric
String queueURI = FlowStream.buildStreamURI(destination).toString();
operations.add(new QueueEnqueue(queueURI.getBytes(), bytes));
LOG.debug("Sending tuple to " + queueURI + ", tuple = " + event);